package net.alan.etl.demo;

import net.alan.etl.impl.AbstractFlowTask;
import net.alan.etl.kafka.FlowParams;

public class DemoTask3 extends AbstractFlowTask {

	@Override
	public String taskId() {
		return "task3";
	}

	@Override
	public void executeTask() {
		System.out.println(params.getNo() + "i am three");
	}

	@Override
	public void initParam(FlowParams params) {
		super.initParam(params);
	}

	@Override
	public String monitorTaskId() {
		return "task2";
	}

}
